package com.ustcinfo.ishare.kafka.monitor.dao;

import com.ustcinfo.ishare.kafka.monitor.bean.KafkaMonitorInfo;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.session.RowBounds;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

/**
 * Created by Shinelon on 2018/3/20.
 */
public interface IKafkaMonitorInfoDao {
    public void insert(KafkaMonitorInfo kafkaMonitorInfo);

    public void removeAll();

    public void removeByTopic(@Param("topic")String topic);

    public List<KafkaMonitorInfo> findKafkaMonitorInfoByTopic(String topic);

    public List<KafkaMonitorInfo> findAllKafkaMonitorInfo();

    public List<KafkaMonitorInfo> findKafkaMonitorInfoByPage(@Param("pageStart") int start,@Param("pageSize")int size);

    public List<KafkaMonitorInfo> findKafkaMonitorInfo(@Param("topicName") String topicName ,@Param("groupName") String groupName ,@Param("beginTimeValue") Long beginTime ,@Param("endTimeValue") Long endTime);
}
